package cn.chengpengper.rpc.proxy.api.consumer;

import cn.chengpengper.rpc.protocol.RpcProtocol;
import cn.chengpengper.rpc.protocol.request.RpcRequest;
import cn.chengpengper.rpc.proxy.api.future.RpcFuture;
import cn.chengpengper.rpc.registry.api.RegistryService;

/**
 * @author chengpeng.hu
 */
public interface Consumer {
    /**
     * 消费者发送 request 请求
     */
    RpcFuture sendRequest(RpcProtocol<RpcRequest> protocol, RegistryService registryService) throws Exception;

}
